//package com.jic.weamop.weBankAMOP.server;
//
//import com.jic.weamop.weBankAMOP.callback.PushCallback13;
//import org.apache.commons.lang3.StringUtils;
//import org.bcos.channel.client.Service;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.beans.factory.annotation.Value;
//import org.springframework.context.annotation.Lazy;
//import org.springframework.stereotype.Component;
//
//import javax.annotation.PostConstruct;
//import java.util.ArrayList;
//import java.util.Arrays;
//import java.util.List;
//
///**
// * Created by CiPHER
// */
//@Component
//@Lazy(false)
//public class AmopServer {
//    @Autowired
//    private Service amopServiceTest;
//
//    @Autowired
//    private PushCallback13 cb13;
//
//    @Value("${amop.consumer.topics}")
//    private String topicConfig;
//
//    @PostConstruct
//    private void initAomp() {
//                    try{
//                        startConsumer(amopServiceTest);
//                    }catch ( Exception ex){
//                        System.out.println("initAomp service error");
//                    }
//    }
//
//    private void startConsumer(Service service) throws Exception {
//        if (StringUtils.isBlank(topicConfig)) {
//            return;
//        }
//        String[] topicArray = topicConfig.split(";");
//        List<String> topicList = new ArrayList<>(Arrays.asList(topicArray));
//        if (topicList.size() <= 0) {
//            return;
//        }
//        service.setTopics(topicList);
//        //处理消息的PushCallback类，参见Callback代码
//        service.setPushCallback(cb13);
//        //启动服务
//        service.run();
//    }
//
//}
